//package com.example.kafka;
//
//import org.springframework.kafka.annotation.KafkaListener;
//import org.springframework.stereotype.Component;
//
//@Component
//public class Consumer {
//
//    @KafkaListener(topics = "test")
//    public void receive(String payload) {
//        System.out.println(payload);
//    }
//}
